/**
 * @filename: MatchSink.java 2020年1月8日
 * @project match-engine  V1.0
 * Copyright(c) 2020 flying-cattle Co. Ltd.
 * All right reserved.
 */
package com.service.socket.rabbitmq.binding;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @ClassName: MatchSink
 * @Description: TODO(定义管道)
 * @author flying-cattle
 * @date 2020年1月8日
 */
public interface MatchSink {


    //接收队列3
    String IN_PUSH_DEPTH = "in-push-depth";

    String IN_ALTER_SPOT_LIST = "in-alter-spot-list";

    String OUT_KLINE_ITEM = "out-kline-item";

    String IN_KLINE_ITEM = "in-kline-item";

    @Input(MatchSink.IN_PUSH_DEPTH)
    SubscribableChannel pushDepth();

    @Input(MatchSink.IN_ALTER_SPOT_LIST)
    SubscribableChannel inAlterSpotList();

    @Output(MatchSink.OUT_KLINE_ITEM)
    SubscribableChannel outKlineItem();

    @Input(MatchSink.IN_KLINE_ITEM)
    SubscribableChannel inKlineItem();
}
